/**
 * 
 */
package com.qdairlines.service.mq.listener;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author pangyannan
 * @date 2017年6月6日
 * @company QingDao Airlines
 * @description  该监听类必须在 applicationContext-mq.xml 中注册
 */
public class ListenerJms implements MessageListener{
	private static final Logger logger = LoggerFactory.getLogger(ListenerJms.class);
	
	@Override
	public void onMessage(Message mq) {
		//接收文本消息
		if(mq instanceof TextMessage){
			TextMessage textMessage = (TextMessage)mq;
			try{
				//提取文本消息
				String textmq = textMessage.getText();
				logger.info("TextMessage接收成功："+textmq);
				
				//接收消息后的业务处理，一般封装一个service

			}catch(Exception e){
				logger.error("TextMessage文本内容解析失败"+textMessage);
			}
		}else{
			logger.error("Message不是TextMessage格式：" +mq);
		}
		
	}
}

